//package com.demo.mq.rabbit.consumer.service;
//
//import org.springframework.amqp.core.Binding;
//import org.springframework.amqp.core.BindingBuilder;
//import org.springframework.amqp.core.DirectExchange;
//import org.springframework.amqp.core.Queue;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
///**
// * Created with intelliJ Idea
// *
// * @Author: ysw
// * @Date: 2021-12-18 14:17
// * @Description: Direct 配置
// */
//@Configuration
//public class DirectRabbitConfig {
//
//    //队列 起名：DirectQueue
//    @Bean
//    public Queue TestDirectQueue() {
//        return new Queue("TestDirectQueue",true);
//    }
//
//    //Direct交换机 起名：TestDirectExchange
//    @Bean
//    DirectExchange TestDirectExchange() {
//        return new DirectExchange("TestDirectExchange");
//    }
//
//    //绑定  将队列和交换机绑定, 并设置用于匹配键：TestDirectRouting
//    @Bean
//    Binding bindingDirect() {
//        return BindingBuilder.bind(TestDirectQueue()).to(TestDirectExchange()).with("TestDirectRouting");
//    }
//}